import { NextResponse } from 'next/server';
import { drizzle } from 'drizzle-orm/mysql2';
import { eq } from 'drizzle-orm';
import { zqwMem0Ai } from '@/db/schema';

// 创建数据库连接
const db = drizzle(process.env.DATABASE_MYSQL_URL!);

/**
 * GET 请求：查询 zqw_mem0ai 表的第一条记录
 */
export async function GET() {
  try {
    console.log('🔍 开始查询表数据...');

    // 查询全部数据
    const allData = await db.select().from(zqwMem0Ai);

    console.log(`✅ 查询成功，共 ${allData.length} 条数据`);

    // 简化返回结构：只返回数据和成功标志
    return NextResponse.json({
      success: true,
      data: allData // 直接返回全部数据数组
    });

  } catch (error) {
    console.error('❌ 数据库查询失败：', error);
    return NextResponse.json(
      {
        success: false,
        error: error instanceof Error ? error.message : '数据库查询失败'
      },
      { status: 500 }
    );
  }
}

/**
 * DELETE 请求：根据 userId 删除记录
 */
export async function DELETE(request: Request) {
  try {
    const { userId } = await request.json();

    if (!userId) {
      return NextResponse.json(
        { success: false, error: 'userId 参数缺失' },
        { status: 400 }
      );
    }
    // console.log(`🗑️ 开始删除用户：${userId}`);
    // 删除指定 userId 的记录（通过 vaule 字段匹配）
    const result = await db.delete(zqwMem0Ai).where(eq(zqwMem0Ai.vaule, userId));

    console.log(`✅ 删除成功`);

    return NextResponse.json({ success: true, message: `用户 ${userId} 已删除` });

  } catch (error) {
    console.error('❌ 数据库删除失败：', error);
    return NextResponse.json(
      { success: false, error: error instanceof Error ? error.message : '数据库删除失败' },
      { status: 500 }
    );
  }
}
